package com.simple.mqtt.server.dispatcher;

import com.simple.mqtt.server.config.MqttBrokerConfig;

import java.util.concurrent.ExecutorService;

/**
 * 默认MQTT消息分发器实现
 * 直接扩展AbstractMqttMessageDispatcher，使用其提供的所有功能
 */
public class DefaultMqttMessageDispatcher extends AbstractMqttMessageDispatcher {

    /**
     * 构造函数
     * @param config MQTT代理配置
     * @param executorService 线程池，用于异步消息分发
     */
    public DefaultMqttMessageDispatcher(MqttBrokerConfig config, ExecutorService executorService) {
        super(config, executorService);
    }
}